<?php
namespace Payment\Wxpay;

require_once "WxPay.Data.php";
require_once "WxPay.Api.php";

/**
 * 
 * 回调基础类
 * @author widyhu
 *
 */
class WxPayNotify extends \WxPayNotifyReply
{

    /**
     * 回调入口
     * @param $msg
     * @return bool|mixed
     */
	final public function Handle($msg)
	{
		//当返回false的时候，表示notify中调用NotifyCallBack回调失败获取签名校验失败，此时直接回复失败
		return \WxpayApi::notify(array($this, 'NotifyCallBack'), $msg);
	}
	
    //查询订单
    public function Queryorder($transaction_id)
    {
        $input = new \WxPayOrderQuery();
        $input->SetTransaction_id($transaction_id);
        return \WxPayApi::orderQuery($input);
    }

    /**
     *
     * 回调方法入口，子类可重写该方法
     * 注意：
     * 1、微信回调超时时间为2s，建议用户使用异步处理流程，确认成功之后立刻回复微信服务器
     * 2、微信服务器在调用失败或者接到回包为非确认包的时候，会发起重试，需确保你的回调是可以重入
     * @param array $data 回调解释出的参数
     * @param string $msg 如果回调处理失败，可以将错误信息输出到该方法
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    public function NotifyProcess($data, &$msg)
    {

        if(!array_key_exists("transaction_id", $data)){
            $msg = "输入参数不正确";
            return false;
        }
        //查询订单，判断订单真实性
        $result = $this->Queryorder($data["transaction_id"]);
        if(array_key_exists("return_code", $result)
            && array_key_exists("result_code", $result)
            && $result["return_code"] == "SUCCESS"
            && $result["result_code"] == "SUCCESS")
        {
            return $result;
        }else{
            $msg = "订单查询失败";
            return false;
        }
    }

    /**
     *
     * notify回调方法，该方法中需要赋值需要输出的参数,不可重写
     * @param array $data
     * @return true回调出来完成不需要继续回调，false回调处理未完成需要继续回调
     */
    final public function NotifyCallBack($data)
    {
        $msg = "OK";
        $result = $this->NotifyProcess($data, $msg);

        if($result){
            $this->SetReturn_code("SUCCESS");
            $this->SetReturn_msg("OK");
        } else {
            $this->SetReturn_code("FAIL");
            $this->SetReturn_msg($msg);
        }
        return $result;
    }

	/**
	 * 
	 * 回复通知
	 * @param bool $needSign 是否需要签名输出
	 */
	final public function ReplyNotify($needSign = true)
	{
		//如果需要签名
		if($needSign == true && $this->GetReturn_code() == "SUCCESS")
		{
			$this->SetSign();
		}
        \WxpayApi::replyNotify($this->ToXml());
	}
}